type google.golang.org/grpc/internal/transport.http2Client
39 uses
google.golang.org/grpc/internal/transport (current package)
client_stream.go#L42: ct *http2Client
http2_client.go#L71: type http2Client struct {
http2_client.go#L333: t := &http2Client{
http2_client.go#L490: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr, handler stats.Handler) *ClientStream {
http2_client.go#L523: func (t *http2Client) Peer() *peer.Peer {
http2_client.go#L533: func (t *http2Client) outgoingGoAwayHandler(g *goAway) (bool, error) {
http2_client.go#L543: func (t *http2Client) createHeaderFields(ctx context.Context, callHdr *CallHdr) ([]hpack.HeaderField, error) {
http2_client.go#L659: func (t *http2Client) createAudience(callHdr *CallHdr) string {
http2_client.go#L674: func (t *http2Client) getTrAuthData(ctx context.Context, audience string) (map[string]string, error) {
http2_client.go#L701: func (t *http2Client) getCallAuthData(ctx context.Context, audience string, callHdr *CallHdr) (map[string]string, error) {
http2_client.go#L757: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr, handler stats.Handler) (*ClientStream, error) {
http2_client.go#L946: func (t *http2Client) closeStream(s *ClientStream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
http2_client.go#L1010: func (t *http2Client) Close(err error) {
http2_client.go#L1088: func (t *http2Client) GracefulClose() {
http2_client.go#L1111: func (t *http2Client) write(s *ClientStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
http2_client.go#L1141: func (t *http2Client) getStream(f http2.Frame) *ClientStream {
http2_client.go#L1151: func (t *http2Client) adjustWindow(s *ClientStream, n uint32) {
http2_client.go#L1160: func (t *http2Client) updateWindow(s *ClientStream, n uint32) {
http2_client.go#L1169: func (t *http2Client) updateFlowControl(n uint32) {
http2_client.go#L1190: func (t *http2Client) handleData(f *parsedDataFrame) {
http2_client.go#L1272: func (t *http2Client) handleRSTStream(f *http2.RSTStreamFrame) {
http2_client.go#L1299: func (t *http2Client) handleSettings(f *http2.SettingsFrame, isFirst bool) {
http2_client.go#L1348: func (t *http2Client) handlePing(f *http2.PingFrame) {
http2_client.go#L1361: func (t *http2Client) handleGoAway(f *http2.GoAwayFrame) error {
http2_client.go#L1442: func (t *http2Client) setGoAwayReason(f *http2.GoAwayFrame) {
http2_client.go#L1457: func (t *http2Client) GetGoAwayReason() (GoAwayReason, string) {
http2_client.go#L1463: func (t *http2Client) handleWindowUpdate(f *http2.WindowUpdateFrame) {
http2_client.go#L1471: func (t *http2Client) operateHeaders(frame *http2.MetaHeadersFrame) {
http2_client.go#L1672: func (t *http2Client) readServerPreface() error {
http2_client.go#L1688: func (t *http2Client) reader(errCh chan<- error) {
http2_client.go#L1764: func (t *http2Client) keepalive() {
http2_client.go#L1849: func (t *http2Client) Error() <-chan struct{} {
http2_client.go#L1853: func (t *http2Client) GoAway() <-chan struct{} {
http2_client.go#L1857: func (t *http2Client) socketMetrics() *channelz.EphemeralSocketMetrics {
http2_client.go#L1864: func (t *http2Client) incrMsgSent() {
http2_client.go#L1871: func (t *http2Client) incrMsgRecv() {
http2_client.go#L1878: func (t *http2Client) getOutFlowWindow() int64 {
http2_client.go#L1893: func (t *http2Client) stateForTesting() transportState {
logging.go#L38: func prefixLoggerForClientTransport(p *http2Client) *internalgrpclog.PrefixLogger {